package com.cango.student.disruptor.disruptor;

import com.lmax.disruptor.WorkHandler;

/**
 * 消费者的作用是读取数据并进行处理。数据的读取已经由Disruptor封装，
 * onEvent()方法为Disruptor框架的回调方法。只需要进行简单的数据处理即可。
 */
public class DisruptorConsumer implements WorkHandler<FileData> {
    private static final String FINIDHED = "EOF";

    @Override
    public void onEvent(FileData event) throws Exception {
        String line = event.getLine();
        if (line.equals(FINIDHED)) {
            return;
        }
        // 消费
//        String[] arrStr = line.split("\t");
//        if (arrStr.length != 2) {
//            return;
//        }
//        int ret = Integer.parseInt(arrStr[0]) + Integer.parseInt(arrStr[1]);
        System.out.println(line);
    }
}